package com.fxkj.cloud.drms.infra.sql.TDengine;

import com.fxkj.cloud.drms.infra.utils.AsyncTask;
import com.google.common.util.concurrent.Futures;
import com.google.common.util.concurrent.ListenableFuture;
import lombok.Data;

import java.sql.PreparedStatement;
import java.util.UUID;

@Data
public class TDEngineStatementTask<T> implements AsyncTask {

    private final UUID rootOrganizationId;
    private final PreparedStatement preStmt;

    public ListenableFuture<TDEngineResultSet<T>> executeAsync(ListenableFuture<T> executeFuture) {
        return Futures.immediateFuture(new TDEngineResultSet(preStmt, executeFuture));
    }


}
